package service.pqueue;

public interface IPQueue {
	public boolean offer(String key, String msg);

	public String poll();

	public int statsLen();

	public long statsOffers();

	public long statsPolls();

	public void flush();

}
